//package com.open.source.demo;
//
//import com.open.source.MqConstant;
//import com.open.source.kafka.AbstractKafkaAutoCommitConsumerListener;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.kafka.clients.consumer.Consumer;
//import org.apache.kafka.clients.consumer.ConsumerRecord;
//import org.springframework.stereotype.Component;
//
///**
// * @author ZonLen since on 2022/8/11 上午10:34
// */
//@Slf4j
//@Component
//public class DemoKafkaAutoCommitConsumerListener extends AbstractKafkaAutoCommitConsumerListener {
//
//  @Override
//  public String[] topics() {
//    return new String[]{
//        MqConstant.TAX_TOPIC_DEMO
//    };
//  }
//
//  @Override
//  public String groupId() {
//    return "ZHANG-LONG1";
//  }
//
//  @Override
//  public void onMessage(ConsumerRecord<String, String> record) {
//    log.info("header host-ip={}", getHeaderByKey("host-ip", record));
//    log.info("offset ＝{}, key ＝{}, value ＝{}", record.offset(), record.key(), record.value());
//
//  }
//
//
//
//}
